package com.marver.common.filter;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import javax.servlet.ServletOutputStream;
import javax.servlet.WriteListener;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletResponseWrapper;
/**
有时我们希望在请求输出之前对response对象进行一些额外的操作，比如从response读出相应的数据，并持久化到数据库中，最后再发往客户端， 但由于response输出流对象没有Buffer功能，且只能读取一次，幸好我们可以通过继承HttpServletResponseWrapper类 来达到我们的需求。下面就具本通过实现此类来完成上面提到的功能。
HttpServletResponseWrapper为我们实现对response对象的后处理提供了帮助,你只需编写一个 HttpServletResponseWrapper的子类，加入自己的功能实现（修饰器模式）。那么子类化 HttpServletResponseWrapper都需要重写那些方法呢？

1、获取response对象，并将输出存放在自定义的流里面，那么关于输 出流（outputStream、writer）的操作都是需要重写的了：
1）以流的方式获取输出——重写getOutputStream() //返回一般为打印流，其底层是对ServletOutputStream引用。
2）以字符方式获取输出——重写getWriter() //直接对ServletOutputStream的引用
3）刷新流——重写flushBuffer()
4）重置流——重写reset()

然后加入新增的获取输出数据的方法就ok了。
2、定义response包装器WapperedResponse继承HttpServletResponseWrapper
 * @author kaede
 *
 */
public class MyResponseWrapper extends HttpServletResponseWrapper {
    private ByteArrayOutputStream buffer = null;
    private ServletOutputStream out = null;
    private PrintWriter writer = null;
    public MyResponseWrapper(HttpServletResponse resp) throws IOException {
        super(resp);
        /**
         * 替换默认的输出端，作为response输出数据的存储空间（即真正存储数据的流）
         */
        buffer = new ByteArrayOutputStream();

        /**
         * response输出数据时是调用getOutputStream()和getWriter()方法获取输出流，再将数据输出到输出流对应的输出端的。
         * 此处指定getOutputStream()和getWriter()返回的输出流的输出端为buffer，即将数据保存到buffer中。
         */
        out = new WapperedOutputStream(buffer);
        writer = new PrintWriter(new OutputStreamWriter(buffer, this.getCharacterEncoding()));
    }

    //重载父类获取outputstream的方法
    @Override
    public ServletOutputStream getOutputStream() throws IOException {
        return out;
    }

    //重载父类获取writer的方法
    @Override
    public PrintWriter getWriter() throws UnsupportedEncodingException {
        return writer;
    }

    /**
     * 这是将数据输出的最后步骤
     * @throws IOException
     */
    @Override
    public void flushBuffer() throws IOException {
        if (out != null) {
            out.flush();
            out.close();
        }
        if (writer != null) {
            writer.flush();
            writer.close();
        }
    }


    @Override
    public void reset() {
        buffer.reset();
    }
    
    public byte[] getResponseData() throws IOException {
        flushBuffer();//将out、writer中的数据强制输出到WapperedResponse的buffer里面，否则取不到数据
        if (this.getContentType()!=null&&this.getContentType().indexOf("/json")!=-1&&buffer!=null){
        	//简体转繁体
        	//return ChineseUtils.toTraditional(new String(buffer.toByteArray())).getBytes();
        	return buffer.toByteArray();
        }
        return buffer.toByteArray();
    }

    //内部类，对ServletOutputStream进行包装，指定输出流的输出端
    private class WapperedOutputStream extends ServletOutputStream {
        private ByteArrayOutputStream bos = null;
        public WapperedOutputStream(ByteArrayOutputStream stream) throws IOException {
            bos = stream;
        }

        //将指定字节写入输出流bos
        @Override
        public void write(int b) throws IOException {
            bos.write(b);
        }
        
		@Override
		public boolean isReady() {
			// TODO Auto-generated method stub
			return false;
		}

		@Override
		public void setWriteListener(WriteListener listener) {
			// TODO Auto-generated method stub
			
		}
    }    
}
